from celery import Celery
from Api import flask_app

celery_app = Celery(flask_app.name)  # 创建 Celery 实例
celery_app.config_from_object("Celery_program.celery_config")  # 通过 Celery 实例加载配置模块

################################################

# 在 Celery_program 包同级目录下执行
# ( 注：-A 可不指定'celery_app'的实例对象，会自动搜索到 Celery_program 包下的 __init__.py文件中的该对象 )

# *** 启动 定时（发布任务）***
# celery -A Celery_program beat --loglevel=info
# celery -A Celery_program.celery_app beat --loglevel=info

# *** 启动 worker（执行任务）***  （ 在 Celery_program 包同级目录下执行 ）
# celery -A Celery_program.app worker --loglevel=info
# celery -A Celery_program.celery_app worker --loglevel=info

# *** 合 并 启 动 ***
# celery -B -A Celery_program.celery_app worker --loglevel=info


# *** 其他格式 ***
# nohup celery beat -s /var/log/celerybeat-schedule  --logfile=/var/log/celerybeat.log  -l info &
# nohup celery worker -f /var/log/boas_celery.log -l INFO &

################################################
